package main

import (
	"fmt"
	"go_study/mq"
)

func main() {
	// 消费数据
	mq.Consumer("", "zbw", callback)
}

func callback(s string) {
	fmt.Printf("msg is :%s\n", s)
}
